package com.qdc.datacenters.constant;

import com.qdc.datacenters.domain.queue.ChatMsgMediaQueue;
import com.qdc.datacenters.domain.queue.ChatMsgQueue;
import com.qdc.datacenters.domain.queue.ChatMsgSensitiveQueue;
import lombok.Data;

import java.util.PriorityQueue;
import java.util.concurrent.LinkedBlockingDeque;

/**
 * @author danmo
 * @date 2024-02-29 15:28
 **/
@Data
public class ChatMsgConstants {

    public static final PriorityQueue<ChatMsgQueue> chatMsgQueues = new PriorityQueue<>(1024);
    public static final LinkedBlockingDeque<ChatMsgMediaQueue> chatMsgMediaQueues = new LinkedBlockingDeque<>(1024);
    public static final LinkedBlockingDeque<ChatMsgSensitiveQueue> chatMsgSensitiveQueues = new LinkedBlockingDeque<>(1024);
}
